In certain scenarios, there may have also been effectively a memory leak that this also fixes.

Fixes #999

This pull request primarily involves changes to the src/StreamJsonRpc/Reflection/MessageFormatterEnumerableTracker.cs file and the test/StreamJsonRpc.Tests/AsyncEnumerableTests.cs file. The changes aim to improve the tracking of outbound request IDs and their corresponding IAsyncEnumerable<T> state machines, and to update the test cases to reflect these changes.

Key changes include:

MessageFormatterEnumerableTracker.cs:

• The dictionary used to map outbound request IDs has been updated to track the list of tokens that represent IAsyncEnumerable<T> state machines it owns. This ensures that the state machines are cleaned up after receiving the final response.

• The GetToken<T>(IAsyncEnumerable<T> enumerable) method has been updated to only track the token if it is serializing a request. This prevents outbound responses that carry enumerables from being disposed of when an inbound response with the same ID is received.

• The CleanUpResources(RequestId requestId) method has been updated to clean up resources associated with outbound request IDs.

AsyncEnumerableTests.cs:

• The AsyncEnumerableTests class has been updated to include a new Client object and a serverProxy for the IClient interface. [1] [2] [3] [4] [5] [6]

• A new test case EnumerableIdDisposal() has been added to test the disposal of enumerable IDs.

• The Server class has been updated to include a Client property and a new method CallbackClientAndYieldOneValueAsync(CancellationToken cancellationToken). [1] [2]

• A new Client class has been added to implement the IClient interface.